#!/usr/bin/env python
# -*- coding:utf-8 -*-
from celery import Celery

import os

if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo_mall.settings.dev'

''' 老师的代码使用了外部文件，较复杂
celery_app = Celery('meiduo')
# 导入配置文件
celery_app.config_from_object('celery_tasks.config')'''

# 创建出Celery对象，指定名称，并指定broker
celery_app = Celery('meiduo', broker="redis://127.0.0.1:6379/15")

# 自动注册celery任务
# 需要指定 所有任务模块所在的包(一个也要用列表)
celery_app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email','celery_tasks.html'])
